package com.xiaoluo.common.queue;

import com.xiaoluo.cd.entity.base.Jobs;
import com.xiaoluo.cd.entity.base.Projects;
import com.xiaoluo.web.form.ProjectForm;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.Objects;
import java.util.concurrent.ConcurrentLinkedQueue;

/**
 * Project : XL-CD
 * Package : com.xiaoluo.common.queue
 * Created by Willian.
 * Date  : 2016/1/6 20:48.
 */
public class JobQueue {
    private final static Logger logger = LoggerFactory.getLogger(JobQueue.class);

    protected static ConcurrentLinkedQueue<Jobs> queue = new ConcurrentLinkedQueue<Jobs>();

    public static void push(Jobs obj){
        logger.info("JobQueue push :{}",obj.getJobName());
        queue.add(obj);
    }
}
